import mqtt from "mqtt"

var client;

const options = {
    protocol: "mqtt",
    keepalive: 10,
    clean: true, // 保留会话
    connectTimeout: 4000, // 超时时间
    reconnectPeriod: 4000, // 重连时间间
    clientId: 'cfb' + Math.random().toString(16).substr(2, 8),//唯一值
    port: 8083,//端口
    host: '43.136.238.10',//地址
    username: 'admin',//id            		 
    password: 'pubilc',//密码
    endpoint: '/mqtt',
    protocolVersion: 4, //MQTT连接协议版本
    reconnectPeriod: 1000, //默认 1000 毫秒，两次重新连接之间的间隔，客户端 ID 重复、认证失败等客户端会重新连接；
}
// 链接接口
const subscribe = function () {
    const connectUrl = 'ws://' + options.host + ':' + options.port + options.endpoint
    client = mqtt.connect(connectUrl, options);
    return client;
}

export {
    subscribe
}